package common.mq.basic.service;

import common.mq.po.Message;
import common.mq.po.Queue;

public interface QueueService {
	
	/**
	 * 路由器调用此接口，调度消息到相应区域
	 * @param m
	 * @throws Exception
	 */
	public void receive(Message m,Queue q) throws Exception;
	
}
